package com.heima.kafka.controller;

import com.alibaba.fastjson.JSON;
import com.heima.kafka.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @author tmh
 * @date 2023/8/24 17:56
 * @description
 */
@RestController
public class HelloController {

    @Resource
    private KafkaTemplate<String,String> kafkaTemplate;

    @GetMapping("/hello")
    public String hello(){
//        kafkaTemplate.send("suyu-topic","黑马程序员");
        User user=new User();
        user.setName("suyu");
        user.setAge(18);
        //我们一般说的发送的xx具体的消息就是消息的值value，也就是参数里面需要传递的data
        //即就是参数data指的就是消息的value，也就是我们要发送的具体的消息
        //这里的data的值就是我们所说的消息，也就是我们消息的值（value）
        kafkaTemplate.send("suyu-topic", JSON.toJSONString(user));
        return "ok";
    }
}
